package top.gbyun.engine.processor;

import akka.actor.ActorContext;
import akka.actor.ActorRef;
import lombok.extern.slf4j.Slf4j;
import top.gbyun.core.ActorSystemContext;
import top.gbyun.core.entity.FlowInfo;

import java.util.HashMap;
import java.util.Map;

/**
 * @author gengbin
 * @date 2024-12-27-14:35
 */
@Slf4j
public class FlowManger {
    protected final ActorSystemContext systemContext;

    private final Map<String, ActorRef> flowActors;

    private final Map<String, FlowInfo> flowInfoMap;


    public FlowManger(ActorSystemContext systemContext) {
        this.systemContext = systemContext;
        this.flowActors = new HashMap<>();
        this.flowInfoMap = new HashMap<>();
    }


    public void init(ActorContext context) {

        // process(context, new RuleChainDeviceMsg())

    }

}
